package net.zhangyun.mock;

public interface Subscriber<T> {

    void onSubscribe(Subscription subscription);

    void onNext(T value);

    void onError(Throwable throwable);

    void onComplete();
}
